package com.umeox.moto.mqtt.request;

public class MqttPublishRequest  extends PersistentRequest {

    public String topic;
    public boolean isRPC = false;
    public String replyTopic;
    public String requestId = "";
    public int qos = 0;

    public MqttPublishRequest(){

    }


    public MqttPublishRequest(String topic, Object message) {
        this.topic = topic;
        this.payloadObj = message;
    }

    @Override
    public String toString() {
        return "MqttPublishRequest{" +
                "topic='" + topic + '\'' +
                ", isRPC=" + isRPC +
                ", replyTopic='" + replyTopic + '\'' +
                ", requestId='" + requestId + '\'' +
                ", qos=" + qos +
                '}';
    }
}